package cn.jbooter.mq.autoconfigure.rocketmq.properties;

import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;

import cn.jbooter.mq.autoconfigure.rocketmq.enu.RocketConsumeMode;


/**
 * consumer 初始化参数
 * @author HeJian
 *
 */
public class RocketConsumerInitInfo {

	private String namesrvAddr;
	private String consumerGroup;
	private MessageModel messageModel;
	private String topic;
	private String[] tag;
	private RocketConsumeMode consumeMode;
	private String beanName;
	
	public String getNamesrvAddr() {
		return namesrvAddr;
	}
	public void setNamesrvAddr(String namesrvAddr) {
		this.namesrvAddr = namesrvAddr;
	}
	public String getConsumerGroup() {
		return consumerGroup;
	}
	public void setConsumerGroup(String consumerGroup) {
		this.consumerGroup = consumerGroup;
	}
	public MessageModel getMessageModel() {
		return messageModel;
	}
	public void setMessageModel(MessageModel messageModel) {
		this.messageModel = messageModel;
	}
	public String getTopic() {
		return topic;
	}
	public void setTopic(String topic) {
		this.topic = topic;
	}
	public String[] getTag() {
		return tag;
	}
	public void setTag(String[] tag) {
		this.tag = tag;
	}
	public RocketConsumeMode getConsumeMode() {
		return consumeMode;
	}
	public void setConsumeMode(RocketConsumeMode consumeMode) {
		this.consumeMode = consumeMode;
	}
	public String getBeanName() {
		return beanName;
	}
	public void setBeanName(String beanName) {
		this.beanName = beanName;
	}
	
}
